package cn.itcast.producer;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Date;

/**
 * 主题消息生产者
 *
 * @author lee.siu.wah
 * @version 1.0
 * <p>File Created at 2020-11-24<p>
 */
@Component
public class TopicProducer {

    @Resource
    private AmqpTemplate amqpTemplate;
    @Value("${mqlog.topic}")
    private String exchange;

    // 生产消息方法
    public void logMessage(String routingKey){
        // 定义消息
        String msg = "主题模式,时间：" + new Date();
        /**
         * String exchange 交换机
         * String routingKey 路由键
         * Object message 消息内容
         */
        amqpTemplate.convertAndSend(exchange, routingKey, msg);
    }
}
